package com.mycloud.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * Created by PC on 2019/1/13.
 */
public interface StreamClient {



    String INPUT = "input";
    String OUTPUT="output";

    String INPUT2 = "myMessageInput2";
    String OUTPUT2="myMessageOutput2";
/*

    @Input(StreamClient.INPUT2)
    SubscribableChannel input();


    @Output(StreamClient.OUTPUT2)
    MessageChannel output();
*/

/*
    @Input(StreamClient.INPUT2)
    SubscribableChannel input2();


    @Output(StreamClient.OUTPUT2)
    MessageChannel output2();
*/

/*    @Input("myMessage")
    SubscribableChannel input();

    @Output("myMessage")
    MessageChannel output();*/
}
